2de6bba345b895b68dfe4c27fd1fa98d137223e7,modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/v1/GridHadoopV1CombineTask.java,GridHadoopV1CombineTask,run,#GridHadoopTaskContext#,32
Before Change
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV2Job jobImpl = (GridHadoopV2Job) taskCtx.job();
JobConf jobConf = jobImpl.hadoopJobContext().getJobConf();
Reducer combiner = U.newInstance(jobConf.getCombinerClass());
After Change
@Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
GridHadoopV2Job jobImpl = (GridHadoopV2Job) taskCtx.job();
JobConf jobConf = new JobConf(jobImpl.hadoopJobContext().getJobConf());
Reducer combiner = U.newInstance(jobConf.getCombinerClass());